package com.xizi.死信队列;

import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.xizi.utils.RabbitUtils;

public class Producer {

   private static final String NORMAL_EXCHANGE = "normal_exchange";

   public static void main(String[] argv) throws Exception {
      try (Channel channel = RabbitUtils.getConnection().createChannel()) {
        channel.exchangeDeclare(NORMAL_EXCHANGE,
        BuiltinExchangeType.DIRECT);
        //设置消息的 TTL 时间 10秒 毫秒单位
//        AMQP.BasicProperties properties = new AMQP.BasicProperties().builder().expiration("10000").build();
          //该信息是用作演示队列个数限制
           for (int i = 1; i <11 ; i++) {
             String message="info"+i;
//            channel.basicPublish(NORMAL_EXCHANGE, "zhangsan",properties,message.getBytes()); //1. 测试过期时间
             channel.basicPublish(NORMAL_EXCHANGE, "zhangsan",null,message.getBytes());
             System.out.println("生产者发送消息:"+message);
          }
       }
    }
}